package com.sh.data.engine.domain.datadev.flink.service;

import com.sh.data.engine.domain.datadev.flink.model.domain.FlinkFunctionDomain;

import java.util.List;

/**
 * @author: zigui.zdf
 * @description:
 * @date: 2021/6/3 14:34
 */
public interface FlinkFunctionService {

    void delete(Long nodeId);

    FlinkFunctionDomain getActiveByNodeId(Long nodeId);

    List<FlinkFunctionDomain> getByNodeIds(List<Long> nodeIds);

    void publish(Long nodeId, Integer status, String userId);

    void rollbackVersion(Long nodeId, Long versionId);

    void saveFunction(
        Long nodeId,
        String className,
        Long resourceNodeId,
        String purpose,
        String format,
        String paramDesc,
        String userId,
        Long projectId);
}
